import org.jctools.queues.SpmcArrayQueue;
import org.jctools.queues.SpscArrayQueue;

public class SendMainService {

	public static void main(String[] args) throws Exception {
		
		
		//final SpscArrayQueue<Integer> arrayQueue=new SpscArrayQueue<Integer>(10);
		final SpmcArrayQueue<Integer> arrayQueue=new SpmcArrayQueue<Integer>(10);

		
		
		arrayQueue.offer(1);
		arrayQueue.offer(2);
		            	
		new java.lang.Thread(){
			public void run(){
				System.out.println(	arrayQueue.poll());
			}
			
		}.start();
		System.out.println(	arrayQueue.poll());
		
		System.out.println(arrayQueue.size());
	  }
}

